package com.leiyuee.flink.tools.constants;

public class KafkaConstant {

    public static final String GROUP_ID = "connect-cluster";
    public static final String CNHUAM0ITPOC85 = "cnhuam0itpoc85:9092";
    public static final String ALL_BOOTSTRAP_SERVERS = "cnhuam0itpoc85:9092,cnhuam0itpoc86:9092,cnhuam0itpoc87:9092,cnhuam0itpoc88:9092,cnhuam0itpoc89:9092";
    public static final String STRING_DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";

}
